package BasedeDatos;

import java.sql.*;
import java.util.*;
import Clases.*;
import Operaciones.OperacionesBD;

public class itemJDBC{
	Connection con;
	Item i = new Item();
	OperacionesBD o;
	
	public Item selectItem(int entry) throws SQLException{
		con = Conexion.conexion();
		Statement stmt = con.createStatement();
		String q = "SELECT entry,comentario,usuario,ip,prioridad FROM item WHERE entry = '"+entry+"' ;";
		try{
		ResultSet sr = stmt.executeQuery(q);
		while (sr.next()){
			i.setEntry(sr.getInt("entry"));
			i.setComentario(sr.getString("comentario"));
			i.setUsuario(sr.getInt("usuario"));
			i.setIp(sr.getString("ip"));
			i.setPrioridad(sr.getInt("prioridad"));
		}
		sr.close();
		}
		catch(SQLException e){
			
		}
		return i;
	}
	
	public ArrayList<Item> selectItemRep() throws SQLException{
		ArrayList<Item> l = new ArrayList<Item>();
		con = Conexion.conexion();
		Statement stmt = con.createStatement();
		String q = "SELECT entry,comentario,usuario,ip,prioridad FROM item WHERE asignado = '0';";
		try{
		ResultSet sr = stmt.executeQuery(q);
		while (sr.next()){
			Item it = new Item();
			it.setEntry(sr.getInt("entry"));
			it.setComentario(sr.getString("comentario"));
			it.setUsuario(sr.getInt("usuario"));
			it.setIp(sr.getString("ip"));
			it.setPrioridad(sr.getInt("prioridad"));
			l.add(it);
		}
		sr.close();
		}
		catch(SQLException e){
			
		}
		return l;
	}
	
	public void asignarItem(Item i, Usuario u) throws SQLException{
		con = Conexion.conexion();
		Statement stmt = con.createStatement();
			String q1 = "UPDATE item SET asignado ='"+1+"' Where entry ='"+i.getEntry()+"';";
		    String q2 = "INSERT INTO itemasignado (usuario,item,prioridad) values('"+u.getGuid()+"' , '"+i.getEntry()+"' , '"+i.getPrioridad()+"');";
		    stmt.executeUpdate(q1);
		    stmt.executeUpdate(q2);
	}
	
	public void limpiarreporteItem() throws SQLException{
		con = Conexion.conexion();
		Statement stmt = con.createStatement();
		String q = "DELETE FROM itemasignado;";
		stmt.executeUpdate(q);
	}
	
	public void insertItem(int entry, String comentario, int usuario, String ip,int prioridad) throws SQLException{
		con = Conexion.conexion();
		Statement stmt = con.createStatement();
		String q = "INSERT INTO item (entry,comentario,usuario,ip,prioridad) VALUES('"+entry+"','"+comentario+"','"+usuario+"','"+ip+"','"+prioridad+"');";
		stmt.executeUpdate(q);
	}
}
